package canalx

type Message[T any] struct {
	Data      []T    `json:"data"`
	Database  string `json:"database"`
	Es        int64  `json:"es"`
	Gtid      string `json:"gtid"`
	Id        int    `json:"id"`
	IsDdl     bool   `json:"isDdl"`
	MysqlType struct {
		Id         string `json:"id"`
		Name       string `json:"name"`
		CreatedOn  string `json:"created_on"`
		CreatedBy  string `json:"created_by"`
		ModifiedOn string `json:"modified_on"`
		ModifiedBy string `json:"modified_by"`
		DeletedOn  string `json:"deleted_on"`
		State      string `json:"state"`
	} `json:"mysqlType"`
	Old []struct {
		Name string `json:"name"`
	} `json:"old"`
	PkNames []string `json:"pkNames"`
	Sql     string   `json:"sql"`
	SqlType struct {
		Id         int `json:"id"`
		Name       int `json:"name"`
		CreatedOn  int `json:"created_on"`
		CreatedBy  int `json:"created_by"`
		ModifiedOn int `json:"modified_on"`
		ModifiedBy int `json:"modified_by"`
		DeletedOn  int `json:"deleted_on"`
		State      int `json:"state"`
	} `json:"sqlType"`
	Table string `json:"table"`
	Ts    int64  `json:"ts"`
	Type  string `json:"type"`
}
